package com.chizha.iot.mqtt.server;

import com.chizha.iot.mqtt.client.ServerMQTT;
import com.jfinal.log.Log;

public class TestPublishMqttMsg extends Thread{

	private static Log log = Log.getLog(TestPublishMqttMsg.class);
	
	@Override
	public void run(){
		
		while (true){	
			try{
				testPublishMqtt();
			} catch (Exception e) {
				e.printStackTrace();
			}
			
			try {
				Thread.sleep(10000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			
		}
	}

	public static void testPublishMqtt() {
		byte[] data = {'a','b','c','d','e','f','g','a','b','c','d','e','f','g','a','b','c','d','e','f','g','a','b','c','d','e','f','g','a','b','c','d','e','f','g','a','b','c','d','e','f','g'};
		log.info("test publish picup msg----------------------");
		//ServerMQTT.publishTopic("A129FB112111/picup", data);
	}

}
